import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
@Test
public void testDistinct()
{
    DistinctIterable<String> distinct = coll.distinct("color", String.class);
    List<String> strList = toDocumentList(distinct);
    assertEquals(6, strList.size());
    assertTrue(strList.contains("Red"));

    distinct = coll.distinct("color", Filters.eq("name", "Alto"), String.class);
    strList = toDocumentList(distinct);
    assertEquals(4, strList.size());
    assertTrue(strList.contains("Red"));
}
 

import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
@Override
public <TResult> DistinctIterable<TResult> distinct(String fieldName, Class<TResult> arg1)
{
    DistinctIterable<TResult> find = collection.distinct(fieldName, arg1);
    ProfiledDistinctIterable<TDocument, TResult> profiledFindIterable = new ProfiledDistinctIterable<TDocument, TResult>(
        find, fieldName, this);
    return profiledFindIterable;
}
 

import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
public ProfiledDistinctIterable(DistinctIterable<TResult> findIterable, String fieldName,
    ProfiledMongoCollection<TDocument> collection)
{
    super();
    this.distinctIterable = findIterable;
    this.fieldName = fieldName;
    this.collection = collection;
}
 

import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
public DistinctIterable<TResult> getDistinceIterable()
{
    return distinctIterable;
}
 

import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
public cfData execute( cfSession _session, cfArgStructData argStruct ) throws cfmRunTimeException {
	MongoDatabase db = getMongoDatabase( _session, argStruct );

	String collection = getNamedStringParam( argStruct, "collection", null );
	if ( collection == null )
		throwException( _session, "please specify a collection" );

	String key = getNamedStringParam( argStruct, "key", null );
	if ( key == null )
		throwException( _session, "please specify a key" );

	cfData query = getNamedParam( argStruct, "query", null );

	try {

		DistinctIterable<String> result;
		if ( query != null )
			result = db.getCollection( collection ).distinct( key, String.class ).filter( getDocument( query ) );
		else
			result = db.getCollection( collection ).distinct( key, String.class );

		cfArrayData arr = cfArrayData.createArray( 1 );

		result.forEach( new Block<String>() {

			@Override
			public void apply( final String st ) {
				try {
					arr.addElement( new cfStringData( st ) );
				} catch ( cfmRunTimeException e ) {}
			}
		} );


		return arr;

	} catch ( MongoException me ) {
		throwException( _session, me.getMessage() );
		return null;
	}
}
 

import com.mongodb.client.DistinctIterable; //导入依赖的package包/类
<T extends IEntity, RESULT> DistinctIterable<RESULT> distinct(Class<T> entity, Class<RESULT> resultClass, String fieldName) throws Exception;