Toggle navigation
Home
byte to org.apache.phoenix.schema.PName
No. of Instances - 2
No. of Commits - 2
No. of Projects - {'pheonix'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Cascading Type Change (Similar)
Pair<byte[],List<Mutation>>
to
Pair<PName,List<Mutation>>
Pair<byte[],List<Mutation>>
to
Pair<PName,List<Mutation>>
Iterator<Pair<byte[],List<Mutation>>>
to
Iterator<Pair<PName,List<Mutation>>>
Add or Remove Method invocation
table.getPhysicalName()
to
index
index.getPhysicalName()
to
table
Update Anonymous class
{ boolean isFirst=true; @Override public boolean hasNext(){ return isFirst || indexes.hasNext(); } @Override public Pair<byte[],List<Mutation>> next(){ if (isFirst) { isFirst=false; return new Pair<byte[],List<Mutation>>(table.getPhysicalName().getBytes(),mutationList); } PTable index=indexes.next(); List<Mutation> indexMutations; try { indexMutations=IndexUtil.generateIndexData(table,index,mutationsPertainingToIndex,connection.getKeyValueBuilder(),connection); if (!sendAll) { TableRef key=new TableRef(index); Map<ImmutableBytesPtr,RowMutationState> rowToColumnMap=mutations.remove(key); if (rowToColumnMap != null) { final List<Mutation> deleteMutations=Lists.newArrayList(); generateMutations(tableRef,timestamp,rowToColumnMap,deleteMutations,null); indexMutations.addAll(deleteMutations); } } } catch ( SQLException e) { throw new IllegalDataException(e); } return new Pair<byte[],List<Mutation>>(index.getPhysicalName().getBytes(),indexMutations); } @Override public void remove(){ throw new UnsupportedOperationException(); } }
to
{ boolean isFirst=true; @Override public boolean hasNext(){ return isFirst || indexes.hasNext(); } @Override public Pair<PName,List<Mutation>> next(){ if (isFirst) { isFirst=false; return new Pair<PName,List<Mutation>>(table.getPhysicalName(),mutationList); } PTable index=indexes.next(); List<Mutation> indexMutations; try { indexMutations=IndexUtil.generateIndexData(table,index,mutationsPertainingToIndex,connection.getKeyValueBuilder(),connection); if (!sendAll) { TableRef key=new TableRef(index); Map<ImmutableBytesPtr,RowMutationState> rowToColumnMap=mutations.remove(key); if (rowToColumnMap != null) { final List<Mutation> deleteMutations=Lists.newArrayList(); generateMutations(tableRef,timestamp,rowToColumnMap,deleteMutations,null); indexMutations.addAll(deleteMutations); } } } catch ( SQLException e) { throw new IllegalDataException(e); } return new Pair<PName,List<Mutation>>(index.getPhysicalName(),indexMutations); } @Override public void remove(){ throw new UnsupportedOperationException(); } }