public class NullMetadataLog<T> extends Object implements org.apache.spark.sql.execution.streaming.MetadataLog<T>, scala.Serializable
| Constructor and Description |
|---|
NullMetadataLog() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(long batchId,
T metadata) |
scala.Option<T> |
get(long batchId) |
scala.Tuple2<Object,T>[] |
get(scala.Option<Object> startId,
scala.Option<Object> endId) |
scala.Option<scala.Tuple2<Object,T>> |
getLatest() |
void |
purge(long thresholdBatchId) |
public boolean add(long batchId,
T metadata)
add in interface org.apache.spark.sql.execution.streaming.MetadataLog<T>public scala.Option<T> get(long batchId)
get in interface org.apache.spark.sql.execution.streaming.MetadataLog<T>public scala.Tuple2<Object,T>[] get(scala.Option<Object> startId, scala.Option<Object> endId)
get in interface org.apache.spark.sql.execution.streaming.MetadataLog<T>public scala.Option<scala.Tuple2<Object,T>> getLatest()
getLatest in interface org.apache.spark.sql.execution.streaming.MetadataLog<T>public void purge(long thresholdBatchId)
purge in interface org.apache.spark.sql.execution.streaming.MetadataLog<T>