public long getWindowMs() {
    return getLong(WINDOW_MS, DEFAULT_WINDOW_MS);
  }
Get the input streams, not including the broadcast streams. Use {@link #getAllInputStreams()} to also get the
broadcast streams.
samza-core/src/main/java/org/apache/samza/config/TaskConfig.java