void function ( final String arg0 , final Fields arg1 ) { this . declareStream ( arg0 , false , arg1 ) ; }
currently , flink only supports the default output stream . thus , parameter streamid must be equals to utils #default_stream_id . concode_field_sep Fields outputSchema concode_field_sep TypeInformation<?> getOutputType concode_elem_sep void declare concode_elem_sep void declare concode_elem_sep int[] getGroupingFieldIndexes concode_elem_sep int compareTo