StreamBroadcastEngineBuilder

class swordfish._engine.StreamBroadcastEngineBuilder(name, table_schema, outputs)

参数:

• name (str)

• table_schema (Table | Dict[str, DataType | str])

• outputs (List[Table])

submit()

Abstract method to build a StreamEngine.

返回:

An instance of a built StreamEngine.

返回类型:

StreamEngine