@Override
    public void persistJoinTable(JoinTableData joinTableData)
    {
        String joinTableName = joinTableData.getJoinTableName();
        String invJoinColumnName = joinTableData.getInverseJoinColumnName();
        Map<Object, Set<Object>> joinTableRecords = joinTableData.getJoinTableRecords();
        String tableName = HBaseUtils.getHTableName(joinTableData.getSchemaName(), joinTableName);
        for (Object key : joinTableRecords.keySet())
        {
            Set<Object> values = joinTableRecords.get(key);
            Object joinColumnValue = key;
            Map<String, Object> columns = new HashMap<String, Object>();
            for (Object childValue : values)
            {
                columns.put(invJoinColumnName + "_" + childValue, childValue);
            }
            if (columns != null && !columns.isEmpty())
            {
                try
                {
                    handler.writeJoinTableData(tableName, joinColumnValue, columns, joinTableName);
                    KunderaCoreUtils.printQuery("Persist Join Table:" + joinTableName, showQuery);
                }
                catch (IOException e)
                {
                    throw new PersistenceException(e);
                }
            }
        }
    }
@ Override public void persistJoinTable ( JoinTableData joinTableData ) { String joinTableName = joinTableData . getJoinTableName ( ) ; String invJoinColumnName = joinTableData . getInverseJoinColumnName ( ) ; Map < Object , Set < Object > > joinTableRecords = joinTableData . getJoinTableRecords ( ) ; String tableName = HBaseUtils . getHTableName ( joinTableData . getSchemaName ( ) , joinTableName ) ; for ( Object key : joinTableRecords . keySet ( ) ) { Set < Object > values = joinTableRecords . get ( key ) ; Object joinColumnValue = key ; Map < String , Object > columns = new HashMap < String , Object > ( ) ; for ( Object childValue : values ) { columns . put ( invJoinColumnName + "_" + childValue , childValue ) ; } if ( columns != null && ! columns . isEmpty ( ) ) { try { handler . writeJoinTableData ( tableName , joinColumnValue , columns , joinTableName ) ; KunderaCoreUtils . printQuery ( "Persist Join Table:" + joinTableName , showQuery ) ; } catch ( IOException e ) { throw new PersistenceException ( e ) ; } } } }
/*
(non-Javadoc)

@see
com.impetus.kundera.client.Client#persistJoinTable(com.impetus.kundera
.persistence.context.jointable.JoinTableData)