connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/SchemaManger.java [27:40]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static Schema getSchema(Object obj) {
        if (obj instanceof Integer) {
            return SchemaBuilder.int32().build();
        } else if (obj instanceof Long) {
            return SchemaBuilder.int64().build();
        } else if (obj instanceof String) {
            return SchemaBuilder.string().build();
        } else if (obj instanceof Date) {
            return SchemaBuilder.time().build();
        } else if (obj instanceof Timestamp) {
            return SchemaBuilder.timestamp().build();
        }
        return SchemaBuilder.string().build();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceTask.java [138:151]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private Schema getSchema(Object obj) {
        if (obj instanceof Integer) {
            return SchemaBuilder.int32().build();
        } else if (obj instanceof Long) {
            return SchemaBuilder.int64().build();
        } else if (obj instanceof String) {
            return SchemaBuilder.string().build();
        } else if (obj instanceof Date) {
            return SchemaBuilder.time().build();
        } else if (obj instanceof Timestamp) {
            return SchemaBuilder.timestamp().build();
        }
        return SchemaBuilder.string().build();
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -