@Test public void getSchemaProviderShouldReturnNullSchemaProvider() { final InputBatch<String> inputBatch = new InputBatch<>(Option.empty(), null, null); SchemaProvider schemaProvider = inputBatch.getSchemaProvider(); assertTrue(schemaProvider instanceof InputBatch.NullSchemaProvider); }
public SchemaProvider getSchemaProvider() { if (batch.isPresent() && schemaProvider == null) { throw new HoodieException("Please provide a valid schema provider class!"); } return Option.ofNullable(schemaProvider).orElse(new NullSchemaProvider()); }
InputBatch { public SchemaProvider getSchemaProvider() { if (batch.isPresent() && schemaProvider == null) { throw new HoodieException("Please provide a valid schema provider class!"); } return Option.ofNullable(schemaProvider).orElse(new NullSchemaProvider()); } }
InputBatch { public SchemaProvider getSchemaProvider() { if (batch.isPresent() && schemaProvider == null) { throw new HoodieException("Please provide a valid schema provider class!"); } return Option.ofNullable(schemaProvider).orElse(new NullSchemaProvider()); } InputBatch(Option<T> batch, String checkpointForNextBatch, SchemaProvider schemaProvider);  InputBatch(Option<T> batch, String checkpointForNextBatch); }
InputBatch { public SchemaProvider getSchemaProvider() { if (batch.isPresent() && schemaProvider == null) { throw new HoodieException("Please provide a valid schema provider class!"); } return Option.ofNullable(schemaProvider).orElse(new NullSchemaProvider()); } InputBatch(Option<T> batch, String checkpointForNextBatch, SchemaProvider schemaProvider);  InputBatch(Option<T> batch, String checkpointForNextBatch); Option<T> getBatch(); String getCheckpointForNextBatch(); SchemaProvider getSchemaProvider(); }
InputBatch { public SchemaProvider getSchemaProvider() { if (batch.isPresent() && schemaProvider == null) { throw new HoodieException("Please provide a valid schema provider class!"); } return Option.ofNullable(schemaProvider).orElse(new NullSchemaProvider()); } InputBatch(Option<T> batch, String checkpointForNextBatch, SchemaProvider schemaProvider);  InputBatch(Option<T> batch, String checkpointForNextBatch); Option<T> getBatch(); String getCheckpointForNextBatch(); SchemaProvider getSchemaProvider();  }