Resultados da pesquisa a pedido "spark-cassandra-connector"
Por que o Apache Spark está executando os filtros no cliente
Sendo novato no apache spark, enfrentando algum problema ao buscar dados do Cassandra no Spark. List<String> dates = Arrays.asList("2015-01-21","2015-01-22"); CassandraJavaRDD<A> aRDD = ...
Apache Spark leva de 5 a 6 minutos para contagem simples de 1 bilhão de linhas de Cassandra
Estou usando o conector Spark Cassandra. Demora de 5 a 6 minutos para buscar dados da tabela Cassandra. No Spark, eu já vi muitas tarefas e Executor no log. O motivo pode ser que o Spark tenha dividido o processo em muitas tarefas! Abaixo está o ...
Lendo de Cassandra usando Spark Streaming
Tenho um problema quando uso o spark streaming para ler a partir de ...
Spark 1.5.1, Cassandra Connector 1.5.0-M2, Cassandra 2.1, Scala 2.10, dependência de goiaba NoSuchMethodError
Novo no ambiente Spark (e relativamente novo no Maven), estou com dificuldades em enviar as dependências necessárias corretamente. Parece que o Spark 1.5.1 tem uma dependência de goiaba-14.0.1 que ele tenta usar e o isPrimitive foi adicionado em ...
Driver Cassandra Datatax lançando CodecNotFoundException
A exceção exata é a seguinte com.datastax.driver.core.exceptions.CodecNotFoundException: codec não encontrado para a operação solicitada: [varchar <-> java.math.BigDecimal] Estas são as versões do software que estou usando Spark 1.5 ...
Passe columnNames dinamicamente para cassandraTable (). Select ()
Estou lendo a consulta de um arquivo em tempo de execução e executando-a no ambiente SPark + Cassandra. Estou executando: sparkContext.cassandraTable.("keyspaceName", "colFamilyName").select("col1", "col2", "col3").where("some condition = ...
O que acontece - NoSuchMethodError: com.datastax.driver.core.ResultSet.fetchMoreResults
cassandra-connector-assembly-2.0.0 construído a partir degithub projeto. comScala 2.11.8, cassandra-driver-core-3.1.0 sc.cassandraTable("mykeyspace", "mytable").select("something").where("key=?", key).mapPartitions(par => { par.map({ row => ...
Como corrigir java.lang.ClassCastException: não é possível atribuir uma instância de scala.collection.immutable.List ao tipo de campo scala.collection.Seq?
Este erro foi o mais difícil de rastrear. Eu não sei o que está acontecendo. Estou executando um cluster Spark na minha máquina de localização. portanto, todo o cluster spark está sob um host que é127.0.0.1 e eu corro no modo ...
java.lang.NoClassDefFoundError: org / apache / spark / Logging
Estou sempre recebendo o seguinte erro. Alguém pode me ajudar por favor? Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/Logging at java.lang.ClassLoader.defineClass1(Native Method) ...
Não foi possível gerar UUIDs no Spark SQL
abaixo está o bloco de código e o erro recebido > creating a temporary views sqlcontext.sql("""CREATE TEMPORARY VIEW temp_pay_txn_stage USING org.apache.spark.sql.cassandra OPTIONS ( table "t_pay_txn_stage", keyspace "ks_pay", cluster "Test ...
Página 1 do 2