dida.d.ts

export default Dida;
declare function Dida(abi: any): void;
declare class Dida {
    constructor(abi: any);
    GraphBuilder: typeof GraphBuilder;
    Graph: typeof Graph;
    Shard: typeof Shard;
    Change: typeof Change;
    ChangeBatch: typeof ChangeBatch;
    Subgraph: typeof Subgraph;
    Node: typeof Node;
    NodeSpec: {
        Input: typeof NodeSpec_Input_tag;
        Map: typeof NodeSpec_Map_tag;
        Index: typeof NodeSpec_Index_tag;
        Join: typeof NodeSpec_Join_tag;
        Output: typeof NodeSpec_Output_tag;
        TimestampPush: typeof NodeSpec_TimestampPush_tag;
        TimestampIncrement: typeof NodeSpec_TimestampIncrement_tag;
        TimestampPop: typeof NodeSpec_TimestampPop_tag;
        Union: typeof NodeSpec_Union_tag;
        Distinct: typeof NodeSpec_Distinct_tag;
        Reduce: typeof NodeSpec_Reduce_tag;
    };
    MapSpec: typeof MapSpec;
    JoinSpec: typeof JoinSpec;
    TimestampPushSpec: typeof TimestampPushSpec;
    TimestampPopSpec: typeof TimestampPopSpec;
    TimestampIncrementSpec: typeof TimestampIncrementSpec;
    IndexSpec: typeof IndexSpec;
    UnionSpec: typeof UnionSpec;
    DistinctSpec: typeof DistinctSpec;
    ReduceSpec: typeof ReduceSpec;
    OutputSpec: typeof OutputSpec;
}
declare function GraphBuilder(): void;
declare class GraphBuilder {
    external: any;
    deinit(): any;
    addSubgraph(arg0: any): any;
    addNode(arg0: any, arg1: any): any;
    connectLoop(arg0: any, arg1: any): any;
    finishAndReset(): any;
}
declare function Graph(arg0: any, arg1: any, arg2: any): void;
declare class Graph {
    constructor(arg0: any, arg1: any, arg2: any);
    external: any;
    deinit(): any;
    validate(): any;
}
declare function Shard(arg0: any): void;
declare class Shard {
    constructor(arg0: any);
    external: any;
    deinit(): any;
    pushInput(arg0: any, arg1: any): any;
    flushInput(arg0: any): any;
    advanceInput(arg0: any, arg1: any): any;
    hasWork(): any;
    doWork(): any;
    popOutput(arg0: any): any;
}
declare function Change(row: any, timestamp: any, diff: any): void;
declare class Change {
    constructor(row: any, timestamp: any, diff: any);
    row: any;
    timestamp: any;
    diff: any;
}
declare function ChangeBatch(lower_bound: any, changes: any): void;
declare class ChangeBatch {
    constructor(lower_bound: any, changes: any);
    lower_bound: any;
    changes: any;
}
declare function Subgraph(id: any): void;
declare class Subgraph {
    constructor(id: any);
    id: any;
}
declare function Node(id: any): void;
declare class Node {
    constructor(id: any);
    id: any;
}
declare function NodeSpec_Input_tag(): void;
declare class NodeSpec_Input_tag {
    tag: string;
    payload: any;
}
declare function NodeSpec_Map_tag(...args: any[]): void;
declare class NodeSpec_Map_tag {
    constructor(...args: any[]);
    tag: string;
    payload: MapSpec;
}
declare function NodeSpec_Index_tag(...args: any[]): void;
declare class NodeSpec_Index_tag {
    constructor(...args: any[]);
    tag: string;
    payload: IndexSpec;
}
declare function NodeSpec_Join_tag(...args: any[]): void;
declare class NodeSpec_Join_tag {
    constructor(...args: any[]);
    tag: string;
    payload: JoinSpec;
}
declare function NodeSpec_Output_tag(...args: any[]): void;
declare class NodeSpec_Output_tag {
    constructor(...args: any[]);
    tag: string;
    payload: OutputSpec;
}
declare function NodeSpec_TimestampPush_tag(...args: any[]): void;
declare class NodeSpec_TimestampPush_tag {
    constructor(...args: any[]);
    tag: string;
    payload: TimestampPushSpec;
}
declare function NodeSpec_TimestampIncrement_tag(...args: any[]): void;
declare class NodeSpec_TimestampIncrement_tag {
    constructor(...args: any[]);
    tag: string;
    payload: TimestampIncrementSpec;
}
declare function NodeSpec_TimestampPop_tag(...args: any[]): void;
declare class NodeSpec_TimestampPop_tag {
    constructor(...args: any[]);
    tag: string;
    payload: TimestampPopSpec;
}
declare function NodeSpec_Union_tag(...args: any[]): void;
declare class NodeSpec_Union_tag {
    constructor(...args: any[]);
    tag: string;
    payload: UnionSpec;
}
declare function NodeSpec_Distinct_tag(...args: any[]): void;
declare class NodeSpec_Distinct_tag {
    constructor(...args: any[]);
    tag: string;
    payload: DistinctSpec;
}
declare function NodeSpec_Reduce_tag(...args: any[]): void;
declare class NodeSpec_Reduce_tag {
    constructor(...args: any[]);
    tag: string;
    payload: ReduceSpec;
}
declare function MapSpec(input: any, mapper: any): void;
declare class MapSpec {
    constructor(input: any, mapper: any);
    input: any;
    mapper: any;
}
declare function JoinSpec(inputs: any, key_columns: any): void;
declare class JoinSpec {
    constructor(inputs: any, key_columns: any);
    inputs: any;
    key_columns: any;
}
declare function TimestampPushSpec(input: any): void;
declare class TimestampPushSpec {
    constructor(input: any);
    input: any;
}
declare function TimestampPopSpec(input: any): void;
declare class TimestampPopSpec {
    constructor(input: any);
    input: any;
}
declare function TimestampIncrementSpec(input: any): void;
declare class TimestampIncrementSpec {
    constructor(input: any);
    input: any;
}
declare function IndexSpec(input: any): void;
declare class IndexSpec {
    constructor(input: any);
    input: any;
}
declare function UnionSpec(inputs: any): void;
declare class UnionSpec {
    constructor(inputs: any);
    inputs: any;
}
declare function DistinctSpec(input: any): void;
declare class DistinctSpec {
    constructor(input: any);
    input: any;
}
declare function ReduceSpec(input: any, key_columns: any, init_value: any, reducer: any): void;
declare class ReduceSpec {
    constructor(input: any, key_columns: any, init_value: any, reducer: any);
    input: any;
    key_columns: any;
    init_value: any;
    reducer: any;
}
declare function OutputSpec(input: any): void;
declare class OutputSpec {
    constructor(input: any);
    input: any;
}