public static Schema getSchemaForType()

in pipelines/etl_integration_java/src/main/java/com/google/cloud/dataflow/solutions/data/SchemaUtils.java [29:43]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public static <T> Schema getSchemaForType(Pipeline p, Class<T> classType) {
        Schema schema;

        try {
            schema = p.getSchemaRegistry().getSchema(classType);
        } catch (NoSuchSchemaException e) {
            LOG.error(e.getMessage());
            throw new IllegalArgumentException(
                    String.format(
                            "Could not find schema for %s",
                            TaxiObjects.TaxiEvent.class.getCanonicalName()));
        }

        return schema;
    }