spark技术分享

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

KafkaWriter Helper Object — Writing Structured Queries to Kafka

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

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

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

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

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

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

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

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

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

ConsumerStrategy Contract — Kafka Consumer Providers

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

KafkaSourceRDDPartition KafkaSourceRDDPartition is…​FIXME

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

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

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

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

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

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