daskos / epos

Write DAG Workflows like epic poems via Mesos, Marathon, Chronos, Spark, Dask
4 stars 1 forks source link

Odo Cassandra Backend #1

Closed kszucs closed 8 years ago

kszucs commented 8 years ago

To support the following conversions:

odo(spark_dataframe, 'cql://cassandrahost::cassandra_table')
odo(pandas_dataframe, 'cql://cassandrahost::cassandra_table')
odo('cql://cassandrahost::cassandra_table', sqlContext)   # spark dataframe
odo('cql://cassandrahost::cassandra_table', pd.DataFrame) # pandas dataframe