public class FileLogger extends java.lang.Object implements Processor<org.apache.spark.streaming.api.java.JavaDStream<java.lang.String>,org.apache.spark.streaming.api.java.JavaDStream<java.lang.String>>
MODULE_EXECUTION_FRAMEWORK, SPARK_DEFAULT_MASTER_URL, SPARK_DEFAULT_STORAGE_LEVEL, SPARK_MASTER_URL_PROP, SPARK_STORAGE_LEVEL_MODULE_OPTION, SPARK_STORAGE_LEVEL_PROP, SPARK_STREAMING_BATCH_INTERVAL_MODULE_OPTION, SPARK_STREAMING_BATCH_INTERVAL_PROP, SPARK_STREAMING_DEFAULT_BATCH_INTERVAL| コンストラクターと説明 |
|---|
FileLogger() |
| 修飾子と型 | メソッドと説明 |
|---|---|
java.util.Properties | getSparkConfigProperties() |
org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> | process(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> input) 入力 DStream を処理し、オプションで出力 DStream を返します。 |
void | setPath(java.lang.String filePath) |
public void setPath(java.lang.String filePath)
public java.util.Properties getSparkConfigProperties()
public org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> process(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> input)
Processor