Functions — github.com/dataArtisans/oscon

CodeHub MCPcopy Create free account

hub / github.com/dataArtisans/oscon / functions

Functions56 in github.com/dataArtisans/oscon

⨍ Functions 56 ◇ Types & classes 16

↓ 12 callersMethodmap

(DataPoint<Long> dataPoint)

src/main/java/com/dataartisans/functions/SawtoothFunction.java:32

↓ 10 callersMethodgetTimeStampMs

src/main/java/com/dataartisans/data/DataPoint.java:18

↓ 7 callersMethodgetValue

src/main/java/com/dataartisans/data/DataPoint.java:26

↓ 4 callersMethodgetKey

src/main/java/com/dataartisans/data/KeyedDataPoint.java:22

↓ 4 callersMethodwithNewValue

src/main/java/com/dataartisans/data/DataPoint.java:34

↓ 1 callersMethodgenerateSensorData

(StreamExecutionEnvironment env)

src/main/java/com/dataartisans/jobs/OsconJob.java:70

↓ 1 callersMethodgetAmplitude

src/main/java/com/dataartisans/data/ControlMessage.java:25

↓ 1 callersMethodkeyWeights

src/main/java/com/dataartisans/functions/KeyedDataGeneratorFunction.java:13

↓ 1 callersMethodrandomJitter

src/main/java/com/dataartisans/sources/TimestampSource.java:78

↓ 1 callersMethodtimeSync

src/main/java/com/dataartisans/sources/TimestampSource.java:64

↓ 1 callersMethodwithKey

src/main/java/com/dataartisans/data/DataPoint.java:42

MethodAssignKeyFunction

src/main/java/com/dataartisans/functions/AssignKeyFunction.java:11

MethodControlMessage

src/main/java/com/dataartisans/data/ControlMessage.java:8

MethodDataPoint

src/main/java/com/dataartisans/data/DataPoint.java:8

MethodInfluxDBSink

(String measurement)

src/main/java/com/dataartisans/sinks/InfluxDBSink.java:20

MethodKeyedDataPoint

src/main/java/com/dataartisans/data/KeyedDataPoint.java:7

MethodSawtoothFunction

src/main/java/com/dataartisans/functions/SawtoothFunction.java:20

MethodTimestampSource

(int periodMs, int slowdownFactor)

src/main/java/com/dataartisans/sources/TimestampSource.java:22

src/main/java/com/dataartisans/sources/TimestampSource.java:48

MethodcheckAndGetNextWatermark

(KeyedDataPoint<Double> dataPoint, long l)

src/main/java/com/dataartisans/functions/SensorDataWatermarkAssigner.java:8

src/main/java/com/dataartisans/sinks/InfluxDBSink.java:32

Methoddeserialize

src/main/java/com/dataartisans/data/DataPointSerializationSchema.java:18

MethodextractTimestamp

(KeyedDataPoint<Double> doubleKeyedDataPoint, long l)

src/main/java/com/dataartisans/functions/SensorDataWatermarkAssigner.java:13

(DataPoint<Long> dataPoint, Collector<KeyedDataPoint<Long>> collector)

src/main/java/com/dataartisans/functions/KeyedDataGeneratorFunction.java:21

(KeyedDataPoint<Double> dataPoint, Collector<KeyedDataPoint<Double>> collector)

src/main/java/com/dataartisans/functions/AmplifierFunction.java:18

(ControlMessage msg, Collector<KeyedDataPoint<Double>> collector)

src/main/java/com/dataartisans/functions/AmplifierFunction.java:28

MethodfromString

src/main/java/com/dataartisans/data/ControlMessage.java:33

src/main/java/com/dataartisans/data/ControlMessage.java:17

MethodgetProducedType

src/main/java/com/dataartisans/data/DataPointSerializationSchema.java:33

(T dataPoint, Context context)

src/main/java/com/dataartisans/sinks/InfluxDBSink.java:37

MethodisEndOfStream

(KeyedDataPoint<Double> doubleKeyedDataPoint)

src/main/java/com/dataartisans/data/DataPointSerializationSchema.java:28

(String[] args)

src/main/java/com/dataartisans/jobs/OsconJobKafka.java:18

(String[] args)

src/main/java/com/dataartisans/jobs/OsconJob.java:25

(String[] args)

src/main/java/com/dataartisans/jobs/SensorSimulatorJob.java:19

(DataPoint<Double> dataPoint)

src/main/java/com/dataartisans/functions/SquareWaveFunction.java:10

(DataPoint<Double> dataPoint)

src/main/java/com/dataartisans/functions/AssignKeyFunction.java:15

(DataPoint<Double> dataPoint)

src/main/java/com/dataartisans/functions/SineWaveFunction.java:10

(Configuration parameters)

src/main/java/com/dataartisans/sources/TimestampSource.java:27

(Configuration parameters)

src/main/java/com/dataartisans/sinks/InfluxDBSink.java:24

(Configuration config)

src/main/java/com/dataartisans/functions/SawtoothFunction.java:25

(Configuration parameters)

src/main/java/com/dataartisans/functions/AmplifierFunction.java:13

MethodrestoreState

(List<Long> state)

src/main/java/com/dataartisans/sources/TimestampSource.java:58

MethodrestoreState

(List<Integer> state)

src/main/java/com/dataartisans/functions/SawtoothFunction.java:40

(SourceContext<DataPoint<Long>> ctx)

src/main/java/com/dataartisans/sources/TimestampSource.java:36

Methodserialize

(KeyedDataPoint<Double> dataPoint)

src/main/java/com/dataartisans/data/DataPointSerializationSchema.java:12

MethodsetAmplitude

(double amplitude)

src/main/java/com/dataartisans/data/ControlMessage.java:29

src/main/java/com/dataartisans/data/KeyedDataPoint.java:26

src/main/java/com/dataartisans/data/ControlMessage.java:21

MethodsetTimeStampMs

(long timeStampMs)

src/main/java/com/dataartisans/data/DataPoint.java:22

src/main/java/com/dataartisans/data/DataPoint.java:30

MethodsnapshotState

(long checkpointId, long checkpointTimestamp)

src/main/java/com/dataartisans/sources/TimestampSource.java:53

MethodsnapshotState

(long checkpointId, long checkpointTimestamp)

src/main/java/com/dataartisans/functions/SawtoothFunction.java:47

src/main/java/com/dataartisans/data/DataPoint.java:46

src/main/java/com/dataartisans/data/KeyedDataPoint.java:17

MethodwithNewKeyAndValue

(String key, R newValue)

src/main/java/com/dataartisans/data/DataPoint.java:38

MethodwithNewValue

src/main/java/com/dataartisans/data/KeyedDataPoint.java:30