Package com.linkedin.venice.spark.input.pubsub

package com.linkedin.venice.spark.input.pubsub

Related Packages

Package	Description
com.linkedin.venice.spark.input
com.linkedin.venice.spark.input.pubsub.raw
com.linkedin.venice.spark.input.hdfs

Class	Description
PubSubMessageConverter	Functional interface for converting PubSub messages to Spark InternalRows.
SparkPubSubInputFormat
SparkPubSubInputPartition	Thin Spark adapter.
SparkPubSubInputPartitionReader	A Spark SQL data source partition reader implementation for Venice PubSub messages.
SparkPubSubPartitionReaderFactory
VenicePubSubMessageToRow	Converts a PubSub message to a Spark InternalRow.