spark技术分享

2012-05-15admin阅读(1721)赞(0)

KafkaWriter Helper Object — Writing Structured Queries to Kafka

2012-05-14admin阅读(1304)赞(0)

InternalKafkaConsumer InternalKafkaConsumer is…​FIXME Getting Single Kafka ConsumerRecord  ...

2012-05-13admin阅读(993)赞(0)

KafkaDataConsumer Contract KafkaDataConsumer is the contract for KafkaDataConsumers that use an InternalKafkaConsu ...

2012-05-12admin阅读(1490)赞(0)

KafkaOffsetRangeLimit KafkaOffsetRangeLimit is the desired offset range limits for starting, ending, and specific ...

2012-05-11admin阅读(1674)赞(0)

KafkaOffsetReader KafkaOffsetReader is used to query a Kafka cluster for partition offsets. KafkaOffsetReader is ...

2012-05-10admin阅读(1578)赞(0)

ConsumerStrategy Contract — Kafka Consumer Providers

2012-05-09admin阅读(1516)赞(0)

KafkaSourceRDDPartition KafkaSourceRDDPartition is…​FIXME

2012-05-08admin阅读(1565)赞(0)

KafkaSourceRDDOffsetRange KafkaSourceRDDOffsetRange is an offset range that one KafkaSourceRDDPartition partition ...

2012-05-07admin阅读(1626)赞(0)

KafkaSourceRDD KafkaSourceRDD is an RDD of Kafka’s ConsumerRecords (with keys and values being collections o ...

2012-05-06admin阅读(1814)赞(0)

KafkaRelation KafkaRelation is a BaseRelation with a TableScan. KafkaRelation is created exclusively when KafkaS ...