tspy.data_structures.utils module

class tspy.data_structures.utils.BinaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.BinaryMapFunction']

evaluate(obj_1, obj_2)

class tspy.data_structures.utils.FastUnaryMapFunction(func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.FilterFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.FilterFunction']

evaluate(obj)

class tspy.data_structures.utils.FlatUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.Function(func)

Bases: object

Methods

Java
apply

class Java

Bases: object

implements = ['java.util.function.Function']

apply(obj)

class tspy.data_structures.utils.IMatcher(func)

Bases: object

Methods

Java
getDeleteCost
getInsertCost
getSubstituteCost
getTransposeCost
match

class Java

Bases: object

implements = ['com.ibm.research.time_series.transforms.reducers.distance.dl.algorithm.IMatcher']

getDeleteCost()

getInsertCost()

getSubstituteCost()

getTransposeCost()

match(obj_1, obj_2)

class tspy.data_structures.utils.IObjectDistanceCalculator(func)

Bases: object

Methods

Java
distance

class Java

Bases: object

implements = ['com.ibm.research.time_series.transforms.reducers.distance.dtw.algorithm.IObjectDistanceCalculator']

distance(o_1, o_2)

class tspy.data_structures.utils.Interpolator(tsc, func)

Bases: object

Methods

Java
getFutureSize
getHistorySize
interpolate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.Interpolator']

getFutureSize()

getHistorySize()

interpolate(history, future, timestamp)

class tspy.data_structures.utils.IteratorMessageSupplier(tsc, py_supplier)

Bases: object

Methods

Java
get

class Java

Bases: object

implements = ['java.util.function.Supplier']

get()

class tspy.data_structures.utils.JavaDataSink(tsc, python_data_sink)

Bases: object

Methods

Java
dump

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.functions.DataSink']

dump(observations)

class tspy.data_structures.utils.JavaMultiDataSink(tsc, python_multi_data_sink)

Bases: object

Methods

Java
dump

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.functions.MultiDataSink']

dump(observations_map)

class tspy.data_structures.utils.JavaMultiTimeSeriesWriteFormat(tsc, python_time_series_writer)

Bases: object

Methods

Java
write

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.io.MultiTimeSeriesWriteFormat']

write(observations_dict, encode_key, encode_value, options)

class tspy.data_structures.utils.JavaPullStreamMultiTimeSeriesReader(py_reader)

Bases: object

Methods

Java
isFinished
isFinite
parse
read

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.io.StreamMultiTimeSeriesReader']

isFinished()

isFinite()

parse(message)

read()

class tspy.data_structures.utils.JavaPullStreamTimeSeriesReader(py_reader)

Bases: object

Methods

Java
isFinished
isFinite
parse
read

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.io.StreamTimeSeriesReader']

isFinished()

isFinite()

parse(message)

read()

class tspy.data_structures.utils.JavaPushStreamMultiTimeSeriesReader(py_reader)

Bases: object

Methods

Java
isFinished
isFinite
parse
read

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.io.StreamMultiTimeSeriesReader']

isFinished()

isFinite()

parse(message)

read()

class tspy.data_structures.utils.JavaPushStreamTimeSeriesReader(py_reader)

Bases: object

Methods

Java
isFinished
isFinite
parse
read

class Java

Bases: object

implements = ['com.ibm.research.time_series.streaming.io.StreamTimeSeriesReader']

isFinished()

isFinite()

parse(message)

read()

class tspy.data_structures.utils.JavaTimeSeriesReader(tsc, py_reader)

Bases: object

Methods

Java
close
end
read
start

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.io.TimeSeriesReader']

close()

end()

read(start, end, inclusive_bounds)

start()

class tspy.data_structures.utils.JavaTimeSeriesWriteFormat(tsc, python_time_series_writer)

Bases: object

Methods

Java
write

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.io.TimeSeriesWriteFormat']

write(observations, encode_value, options)

class tspy.data_structures.utils.JavaToPythonBinaryTransformFunction(tsc, py_func)

Bases: object

Methods

Java
call

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.transform.python.PythonBinaryTransformFunction']

call(j_time_series_l, j_time_series_r, start, end, inclusive_bounds)

class tspy.data_structures.utils.JavaToPythonUnaryTransformFunction(tsc, py_func)

Bases: object

Methods

Java
call

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.transform.python.PythonUnaryTransformFunction']

call(j_time_series, start, end, inclusive_bounds)

class tspy.data_structures.utils.NaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.NaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.ObservationToKeyUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(j_observation)

class tspy.data_structures.utils.PairUnaryMapFunction(func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj_j_pair)

class tspy.data_structures.utils.Record(tsc, j_obj=None, **kwargs)

Bases: object

Methods

__call__(**kwargs)

Call self as a function.

Java
get
keys
set
toString

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.utils.Record']

get(key)

keys()

set(key, value)

toString()

class tspy.data_structures.utils.ReduceTimeSeriesUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(j_ts)

class tspy.data_structures.utils.SegmentFlatUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(j_seg)

class tspy.data_structures.utils.SegmentUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(j_segment)

class tspy.data_structures.utils.SeriesConsumer(tsc, func)

Bases: object

Methods

Java
accept

class Java

Bases: object

implements = ['java.util.function.Consumer']

accept(j_series)

class tspy.data_structures.utils.SeriesFilterFunction(tsc, func)

Bases: object

Methods

Java
apply

class Java

Bases: object

implements = ['java.util.function.Function']

apply(j_series)

class tspy.data_structures.utils.SeriesUnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(j_obs_coll)

class tspy.data_structures.utils.SeriesWithKeyUnaryMapfunctionToSeries(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj_j_pair)

class tspy.data_structures.utils.TimeSeriesFilterFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.FilterFunction']

evaluate(j_ts)

class tspy.data_structures.utils.UnaryListPairMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(list_obj)

class tspy.data_structures.utils.UnaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.UnaryMapFunctionResultingInOptional(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.UnaryMapFunctionTupleResultingInOptional(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.UnaryMapFunction']

evaluate(obj)

class tspy.data_structures.utils.ValueAndSeriesBiFunction(tsc, func)

Bases: object

Methods

Java
apply

class Java

Bases: object

implements = ['java.util.function.BiFunction']

apply(j_series, state)

class tspy.data_structures.utils.ValueAndTimeSeriesBinaryMapFunction(tsc, func)

Bases: object

Methods

Java
evaluate

class Java

Bases: object

implements = ['com.ibm.research.time_series.core.functions.BinaryMapFunction']

evaluate(value, j_ts)

tspy.data_structures.utils.cast_to_j_if_necessary(obj, tsc)

tspy.data_structures.utils.cast_to_py_if_necessary(tsc, obj, obj_type=None)

tspy.data_structures.utils.day(jvm, num_days, unit)

tspy.data_structures.utils.hour(jvm, num_hours, unit)

tspy.data_structures.utils.minute(jvm, num_minutes, unit)

tspy.data_structures.utils.second(jvm, num_seconds, unit)