Package org.apache.phoenix.util

Examples of org.apache.phoenix.util.ColumnInfo

49
50
51
52
53
54
55
56
57
58
59
60
61

    @Test
    public void testBuildColumnInfoList() {
        List<ColumnInfo> columnInfoList = ImmutableList.of(
                new ColumnInfo("idCol", PDataType.INTEGER.getSqlType()),
                new ColumnInfo("unsignedIntCol", PDataType.UNSIGNED_INT.getSqlType()),
                new ColumnInfo("stringArrayCol", PDataType.INTEGER_ARRAY.getSqlType()));

        Configuration conf = new Configuration();
        CsvToKeyValueMapper.configureColumnInfoList(conf, columnInfoList);
        List<ColumnInfo> fromConfig = CsvToKeyValueMapper.buildColumnInfoList(conf);
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
76
77
    @Test
    public void testBuildColumnInfoList_ContainingNulls() {
        // A null value in the column info list means "skip that column in the input"
        List<ColumnInfo> columnInfoListWithNull = Lists.newArrayList(
                new ColumnInfo("idCol", PDataType.INTEGER.getSqlType()),
                null,
                new ColumnInfo("unsignedIntCol", PDataType.UNSIGNED_INT.getSqlType()),
                new ColumnInfo("stringArrayCol", PDataType.INTEGER_ARRAY.getSqlType()));

        Configuration conf = new Configuration();
        CsvToKeyValueMapper.configureColumnInfoList(conf, columnInfoListWithNull);
        List<ColumnInfo> fromConfig = CsvToKeyValueMapper.buildColumnInfoList(conf);
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
        String tableName = "SCHEMANAME.TABLENAME";
        char delimiter = '!';

        List<ColumnInfo> columnInfoList = ImmutableList.of(
                new ColumnInfo("MYCOL", PDataType.INTEGER.getSqlType()));

        CsvBulkImportUtil.initCsvImportJob(
                conf, tableName, delimiter, null, columnInfoList, true);

        assertEquals(tableName, conf.get(CsvToKeyValueMapper.TABLE_NAME_CONFKEY));
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
    private CsvUpsertExecutor upsertExecutor;

    @Before
    public void setUp() throws SQLException {
        columnInfoList = ImmutableList.of(
                new ColumnInfo("ID", Types.BIGINT),
                new ColumnInfo("NAME", Types.VARCHAR),
                new ColumnInfo("AGE", Types.INTEGER),
                new ColumnInfo("VALUES", PDataType.INTEGER_ARRAY.getSqlType()));

        preparedStatement = mock(PreparedStatement.class);
        upsertListener = mock(CsvUpsertExecutor.UpsertListener.class);
        conn = DriverManager.getConnection(getUrl());
        upsertExecutor = new CsvUpsertExecutor(conn, columnInfoList, preparedStatement, upsertListener, ":");
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
                Integer sqlType = unqualifiedColumnMap.get(rowkey);
                if (sqlType == null) {
                    throw new SQLExceptionInfo.Builder(SQLExceptionCode.PRIMARY_KEY_MISSING)
                         .setColumnName(rowkey).setTableName(fullTableName).build().buildException();
                }
                columnMetadata[position] = new ColumnInfo(rowkey, sqlType);
                position++;
            }
           
            this.upsertStatement = QueryUtil.constructUpsertStatement(fullTableName, Arrays.asList(columnMetadata));
            logger.info(" the upsert statement is {} " ,this.upsertStatement);
View Full Code Here
217
218
219
220
221
222
223
224
225
226
                if (sqlType == null) {
                   throw new SQLExceptionInfo.Builder(SQLExceptionCode.COLUMN_NOT_FOUND)
                        .setColumnName(columnName).setTableName(this.fullTableName).build().buildException();
                }
            }
            columnMetadata[position] = new ColumnInfo(columnName, sqlType);
            position++;
       }
       return position;
    }
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
            final List<? extends ColumnProjector> projectedColumns = queryPlan.getProjector().getColumnProjectors();
            columnInfos = Lists.newArrayListWithCapacity(projectedColumns.size());
            columnInfos = Lists.transform(projectedColumns, new Function<ColumnProjector,ColumnInfo>() {
              @Override
        public ColumnInfo apply(final ColumnProjector columnProjector) {
          return new ColumnInfo(columnProjector.getName(), columnProjector.getExpression().getDataType().getSqlType());
        }
             
            });
     } catch (SQLException e) {
            LOG.error(String.format(" Error [%s] parsing SELECT query [%s] ",e.getMessage(),sqlQuery));
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
  }
 
  public void write(PreparedStatement statement, List<ColumnInfo> columnMetadataList) throws SQLException {
    for (int i = 0; i < columnMetadataList.size(); i++) {
      Object o = values.get(i);
      ColumnInfo columnInfo = columnMetadataList.get(i);
      byte type = (fieldSchemas == null) ? DataType.findType(o) : fieldSchemas[i].getType();
      try {
                Object upsertValue = convertTypeSpecificValue(o, type, columnInfo.getSqlType());
                if (upsertValue != null) {
                    statement.setObject(i + 1, upsertValue, columnInfo.getSqlType());
                } else {
                    statement.setNull(i + 1, columnInfo.getSqlType());
                }
            } catch (RuntimeException re) {
                throw new RuntimeException(String.format("Unable to process column %s, innerMessage=%s"
                        ,columnInfo.toString(),re.getMessage()),re);
               
            }
    }
   
    statement.execute();
View Full Code Here
35
36
37
38
39
40
41
42
43
*/
public class ColumnInfoToStringEncoderDecoderTest {

    @Test
    public void testEncode() {
        final ColumnInfo columnInfo = new ColumnInfo("col1", PDataType.VARCHAR.getSqlType());
        final String encodedColumnInfo = ColumnInfoToStringEncoderDecoder.encode(Lists.newArrayList(columnInfo));
        assertEquals(columnInfo.toString(),encodedColumnInfo);
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
        assertEquals(columnInfo.toString(),encodedColumnInfo);
    }
   
    @Test
    public void testDecode() {
        final ColumnInfo columnInfo = new ColumnInfo("col1", PDataType.VARCHAR.getSqlType());
        final String encodedColumnInfo = ColumnInfoToStringEncoderDecoder.encode(Lists.newArrayList(columnInfo));
        assertEquals(columnInfo.toString(),encodedColumnInfo);
    }
View Full Code Here
TOP

Related Classes of org.apache.phoenix.util.ColumnInfo

  • org.apache.phoenix.flume.serializer.BaseEventSerializer
  • org.apache.phoenix.mapreduce.CsvBulkImportUtilTest
  • org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest
  • org.apache.phoenix.pig.hadoop.PhoenixRecord
  • org.apache.phoenix.pig.PhoenixPigConfiguration
  • org.apache.phoenix.pig.util.ColumnInfoToStringEncoderDecoderTest
  • org.apache.phoenix.pig.util.SqlQueryToColumnInfoFunction
  • org.apache.phoenix.pig.util.SqlQueryToColumnInfoFunctionTest
  • org.apache.phoenix.util.csv.CsvUpsertExecutorTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.