Use the following commands to add the kubectl autocomplete to zsh:
mkdir -p ~/.oh-my-zsh/custom/plugins/kubectl-autocomplete/
kubectl completion zsh > ~/.oh-my-zsh/custom/plugins/kubectl-autocomplete/kubectl-autocomplete.plugin.zsh
public static void main(String[] args) throws Exception { | |
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); | |
DataStream<Tuple1<String>> stream = ... | |
DataStream<Tuple1<String>> filters = ... | |
stream | |
.keyBy(0) | |
.connect(filters.keyBy(0)) // partition both streams on same field and connect them | |
.flatMap(new StreamFilter()) // apply CoFlatMap function to update filters and to filter data |