Schema<KeyValue<Integer, String>> kvSchema = Schema.KeyValue(
Schema.INT32,
Schema.STRING,
KeyValueEncodingType.SEPARATED
);
Created
July 9, 2019 07:39
-
-
Save sijie/e36924e2eb02658da73695071eceb280 to your computer and use it in GitHub Desktop.
KeyValue Schema Example
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment