Module: Dataflow::Nodes

Defined in:

lib/dataflow/nodes/upsert_node.rb,
lib/dataflow/nodes/map_node.rb,
lib/dataflow/nodes/data_node.rb,
lib/dataflow/nodes/join_node.rb,
lib/dataflow/nodes/merge_node.rb,
lib/dataflow/nodes/compute_node.rb,
lib/dataflow/nodes/snapshot_node.rb,
lib/dataflow/nodes/sql_query_node.rb,
lib/dataflow/nodes/select_keys_node.rb,
lib/dataflow/nodes/filter/where_node.rb,
lib/dataflow/nodes/export/to_csv_node.rb,
lib/dataflow/nodes/filter/newest_node.rb,
lib/dataflow/nodes/runtime_query_node.rb,
lib/dataflow/nodes/read_only_data_node.rb,
lib/dataflow/nodes/filter/drop_while_node.rb,
lib/dataflow/nodes/mixin/rename_dotted_fields.rb,
lib/dataflow/nodes/transformation/to_time_node.rb,
lib/dataflow/nodes/mixin/add_internal_timestamp.rb

Overview

Interface for a node that behaves as a dataset. Does not support any write operation. Inherit and override to implement custom behavior.

Defined Under Namespace

Modules: Export, Filter, Mixin, Transformation Classes: ComputeNode, DataNode, JoinNode, MapNode, MergeNode, ReadOnlyDataNode, RuntimeQueryNode, SelectKeysNode, SnapshotNode, SqlQueryNode, UpsertNode